package cn.doitedu.demo3;

import cn.doitedu.demo1.EventBean;
import org.apache.flink.api.common.functions.RuntimeContext;
import org.apache.flink.util.Collector;

import java.io.IOException;

public interface RuleCalculatorV3 {

    /**
     * 初始化--》封装的上flink中的open()中的代码
     */
    void init(RuntimeContext runtimeContext,String ruleParam);


    /**
     * 处理逻辑--》封装的上flink中的processElement()中的代码
     * @param eventBean
     * @param out
     * @throws IOException
     */
    void calculate(EventBean eventBean, Collector<String> out) throws IOException;

}
